package com.chukun.multi.immutable;

/**
 * 与运维中心对接的类
 */
public class OMCAgent  extends  Thread{

    @Override
    public void run() {
        boolean isTableModificationMsg = false;
        String updateTableName=null;
        while (true){
            /**
             * 从与OMC连接的socket中读取消息并进行解析，
             * 解析到数据表更新消息后，重置MMSCRouter对象
             */
            if(isTableModificationMsg){
                if("MMSCInfo".equals(updateTableName)){
                    MMSCRouter.setInstance(new MMSCRouter());
                }
            }
        }
    }
}
